package com.yuw.consumerandproducer;

public class Consumer extends Thread {
    // 属性
    private MyStack myStack;

    // 构造方法
    public Consumer(MyStack myStack) {
        this.myStack = myStack;
    }

    @Override
    public void run() {
        // 消费者业务逻辑地方
        // 一直生产
        while (true){
            // 消费一个产品
            System.out.println("消费者消费了一产品，出库");
            // 出栈
            Object obj = myStack.pop();

            // 休眠1s
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
